package com.gzhryc.common.kafka.consumer.interfaces;


import java.util.List;

import com.gzhryc.common.kafka.models.ConsumerEvent;

/**
 * Kafka接收事件监听者
 * @author zhanghao
 *
 */
public interface KafkaConsumerEventListener {
	
	/**
	 * Consumer启动事件
	 */
	public void start(String topic);
	
	/**
	 * Consumer接收消息事件
	 */
	public void receive(List<ConsumerEvent> events);
	
	/**
	 * Consumer关闭事件
	 */
	public void close(String topic);
	
}
